package net.csdn.business.notify.handler.service;


import net.csdn.business.notify.common.pipeline.domain.PrivateTaskInfo;
import net.csdn.business.notify.common.pipeline.domain.TaskInfo;

/**
 * @ClassName MqConsumeService
 * @Description 消费消息服务
 * @Author zhangyl
 * @Date 2023/11/30 14:37
 */
public interface IMqConsumeService {

    /**
     * 从MQ拉到通知消息进行消费，发送消息
     *
     * @param taskInfo
     */
    void consumeRemindMsg(TaskInfo taskInfo);

    /**
     * 从MQ拉到直达类消息进行消费，发送消息
     *
     * @param taskInfo
     */
    void consumeDirectMsg(TaskInfo taskInfo);


    /**
     * 从MQ拉到私信消息进行消费，发送消息
     *
     * @param taskInfo
     */
    void consumePrivateMsg(PrivateTaskInfo taskInfo);


}
